package com.omuao.message.queue.service.push.impl;

import com.omuao.message.queue.manager.DelayQueueManager;
import com.omuao.message.queue.service.push.PushService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

/**
 * @author omuao
 */
@Service
public class PushServiceImpl implements PushService {
    @Autowired
    DelayQueueManager delayQueueManager;

    @Override
    public void commit(String message) {
        delayQueueManager.commit(message);
    }

    @Override
    public void commit(String id, String message) {
        delayQueueManager.commit(id, message);
    }

    @Override
    public void commit(String message, Long timestamp) {
        delayQueueManager.commit(message, timestamp);
    }

    @Override
    public void commit(String id, String message, Long timestamp) {
        delayQueueManager.commit(id, message, timestamp);
    }
}
